package com.lgj.rocketmq.annotation;

import org.apache.rocketmq.common.protocol.heartbeat.MessageModel;
import org.springframework.stereotype.Component;

import java.lang.annotation.*;

@Component
@Documented
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
public @interface RocketMqConsumer {
    String group() default "";

    String instanceName() default "";

    MessageModel messageModel() default MessageModel.CLUSTERING;

    String maxReconsumeTimes() default "";
}
